python socket.socket()函数 套接字详解及TCP、UDP程序示例(粘包等) |
您所在的位置:网站首页 › socket connect函数返回值 › python socket.socket()函数 套接字详解及TCP、UDP程序示例(粘包等) |
文章目录
socket的定义套接字的工作流程socket函数使用socket函数用法服务端套接字函数客户端套接字函数公共用途的套接字函数面向文件的套接字方法打电话的流程演示服务端.py客户端.py
基于TCP的套接字基于UDP的套接字udp服务端udp客户端示例服务端客户端
模拟QQ聊天,多个客户端和服务端通信其他常见问题如粘包等
socket的定义
Socket是应用层与TCP/IP协议族通信的中间软件抽象层,它是一组接口。在设计模式中,Socket其实就是一个门面模式,它把复杂的TCP/IP协议族隐藏在Socket接口后面,对用户来说,一组简单的接口就是全部,让Socket去组织数据,以符合指定的协议。所以,我们无需深入理解tcp/udp协议,socket已经为我们封装好了,我们只需要遵循socket的规定去编程,写出的程序自然就是遵循tcp/udp标准的。 补充:也有人将socket说成ip+port,ip是用来标识互联网中的一台主机的位置,而port是用来标识这台机器上的一个应用程序,ip地址是配置到网卡上的,而port是应用程序开启的,ip与port的绑定就标识了互联网中独一无二的一个应用程序,而程序的pid是同一台机器上不同进程或者线程的标识 套接字的工作流程
略 基于UDP的套接字 udp服务端ss = socket() # 创建一个服务器的套接字 ss.bind() # 绑定服务器套接字 inf_loop: # 服务器无限循环 cs = ss.recvfrom()/ss.sendto() # 对话(接收与发送) ss.close() # 关闭服务器套接字 udp客户端cs = socket() # 创建客户套接字 comm_loop: # 通讯循环 cs.sendto()/cs.recvfrom() # 对话(发送/接收) cs.close() # 关闭客户套接字 示例 服务端 # -*- coding: utf-8 -*- """ @File : 191226_基于UDP协议的socket_server端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : [email protected] @Software: PyCharm """ import socket ip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) udp_server_client.bind(ip_port) while True: msg, addr = udp_server_client.recvfrom(BUFSIZE) print(msg.decode('utf-8'), addr) udp_server_client.sendto(msg.upper(), addr) 客户端 # -*- coding: utf-8 -*- """ @File : 191226_基于UDP协议的socket_client端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : [email protected] @Software: PyCharm """ import socket ip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) while True: msg = input('>>: ').strip() if not msg: continue udp_server_client.sendto(msg.encode('utf-8'), ip_port) back_msg, addr = udp_server_client.recvfrom(BUFSIZE) print(back_msg.decode('utf-8'), addr) 模拟QQ聊天,多个客户端和服务端通信服务端: # -*- coding: utf-8 -*- """ @File : 191228_多个客户端与服务端通信_server端.py @Time : 2019/12/28 10:46 @Author : Dontla @Email : [email protected] @Software: PyCharm """ import socket ip_port = ('192.168.1.49', 9000) udp_server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) udp_server_sock.bind(ip_port) while True: qq_msg, addr = udp_server_sock.recvfrom(1024) print('来自[{}:{}]的一条消息:{}'.format(addr[0], addr[1], qq_msg.decode('utf-8'))) back_msg = input('回复消息: ').strip() udp_server_sock.sendto(back_msg.encode('utf-8'), addr)客户端: # -*- coding: utf-8 -*- """ @File : 191228_多个客户端与服务端通信_client端1.py @Time : 2019/12/28 10:51 @Author : Dontla @Email : [email protected] @Software: PyCharm """ import socket BUFSIZE = 1024 udp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) qq_name_dic = { 'TOM': ('192.168.1.49', 9000), 'JACK': ('192.168.1.49', 9000), '一棵树': ('192.168.1.49', 9000), '武大郎': ('192.168.1.49', 9000), } while True: qq_name = input('请选择聊天对象: ').strip() while True: if not qq_name or qq_name not in qq_name_dic: break msg = input('请输入消息,回车发送: ').strip() if msg == 'quit': break if not msg: continue udp_client_socket.sendto(msg.encode('utf-8'), qq_name_dic[qq_name]) back_msg, addr = udp_client_socket.recvfrom(BUFSIZE) print('来自[{}:{}]的一条消息:{}'.format(addr[0], addr[1], back_msg.decode('utf-8'))) # udp_client_socket.close()略 引用文章1:【Python3之socket编程】 |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |